package com.lds.memory.kafka.consumer;

import com.lds.memory.kafka.partition.Partition;

import java.util.Collection;

public abstract class AbstractConsumer implements IConsumer {

    private final Partition partition;

    public AbstractConsumer(Partition partition) {
        this.partition = partition;
    }

    @Override
    public void consumer() {
        Collection list = partition.acquire();
        consumer(list);
    }

    public <T> void consumer(Collection<T> list) {

    }
}
